//package com.example.flow;
//
//import org.junit.Test;
//
//import java.util.concurrent.Flow;
//
///**
// * flow
// *
// * @author qingyan 2022-01-11
// */
//public class FlowTest {
//    @Test
//    public void flow1(){
//        Flow.Publisher publisher = subscriber -> {
//            for (int i = 0; i < 100; i++) {
//                subscriber.onNext(i);
//            }
//        };
//
//
//        publisher.subscribe(new Flow.Subscriber() {
//
//            private Flow.Subscription subscription;
//            @Override
//            public void onSubscribe(Flow.Subscription subscription) {
//                this.subscription = subscription;
//                subscription.request(100);
//            }
//
//            @Override
//            public void onNext(Object item) {
//                System.out.println(item);
//            }
//
//            @Override
//            public void onError(Throwable throwable) {
//                System.err.println(throwable);
//            }
//
//            @Override
//            public void onComplete() {
//                System.out.println("complete");
//            }
//        });
//
//
//
//    }
//
//}
